package com.kingsoft.dc.khaos.module

import com.kingsoft.dc.khaos.{DataSetChannel, KhaosContext, SchemaChannel}
import org.apache.spark.rdd.RDD

/**
  * Created by chengguangqing on 2019/6/2.
  */
trait TSinkSource {

  def strategy(_mid: String,
               kc: KhaosContext,
               config: String,
               dependence: String,
               dataCollector: DataSetChannel,
               declarer: SchemaChannel): Any
}
